package com.cloud.logger.zchain.zchainclient.kafka;

//import com.cloud.logger.zchain.common.entity.AngelaLoggerEntity;
//import com.cloud.logger.zchain.common.entity.AngelaLoggerProject;
//import com.google.gson.Gson;
//import com.google.gson.GsonBuilder;
//import org.springframework.stereotype.Component;
//
///**
// * User: wcy
// * Date: 2017/11/1
// * Time: 9:39
// */
//@Component
//public class KafkaSender {
////    @Autowired
////    private KafkaTemplate kafkaTemplate;
//    private Gson gson = new GsonBuilder().create();
//    /**
//     * 发送消息到kafka,主题为test
//     */
//    public void sendTest(){
////        kafkaTemplate.send("test","hello,kafka  "  + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS")));
//    }
//
//    /**
//     * 发送消息到kafka,主题为test
//     */
//    public void saveLogger(AngelaLoggerEntity logger){
// //       kafkaTemplate.send("test", gson.toJson(logger));
//    }
//
//    public void updateLogger(String id, AngelaLoggerEntity logger) {
// //       kafkaTemplate.send("test1", gson.toJson(logger));
//    }
//
//    public void saveLoggerProject(AngelaLoggerProject logger) {
//    }
//}
